package com.wondertek.poms.bc.mqListener;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.wondertek.poms.bc.manager.StartProcess;
import com.wondertek.poms.common.constant.Constants;

import lombok.extern.slf4j.Slf4j;

//@Component
@Slf4j
@RabbitListener(queues = Constants.QUEUE_SYNC_CONTENT) // 监听队列
public class SyncContentListener {
    @Autowired
    private StartProcess startProcess;

    /**
     * <p><b>Title:</b> receiveContentTopic</p>
     * <p><b>Description:</b> 内容快速同步消息队列</p>
     *
     * @param message
     * @author douzi
     */
    @RabbitHandler
    public void receiveContentTopic(String message) {
    	log.info("内容同步主流程|mq消息：" + message);
//    	startProcess.fastProcess(message);
    }
}
